/**
 * Software License, Version 1.0
 * 
 * Copyright 2003 The Trustees of Indiana University.  All rights reserved.
 * 
 *
 *Redistribution and use in source and binary forms, with or without 
 *modification, are permitted provided that the following conditions are met:
 *
 *1) All redistributions of source code must retain the above copyright notice,
 * the list of authors in the original source code, this list of conditions and
 * the disclaimer listed in this license;
 *2) All redistributions in binary form must reproduce the above copyright 
 * notice, this list of conditions and the disclaimer listed in this license in
 * the documentation and/or other materials provided with the distribution;
 *3) Any documentation included with all redistributions must include the 
 * following acknowledgement:
 *
 *"This product includes software developed by the Community Grids Lab. For 
 * further information contact the Community Grids Lab at 
 * http://communitygrids.iu.edu/."
 *
 * Alternatively, this acknowledgement may appear in the software itself, and 
 * wherever such third-party acknowledgments normally appear.
 * 
 *4) The name Indiana University or Community Grids Lab or NaradaBrokering, 
 * shall not be used to endorse or promote products derived from this software 
 * without prior written permission from Indiana University.  For written 
 * permission, please contact the Advanced Research and Technology Institute 
 * ("ARTI") at 351 West 10th Street, Indianapolis, Indiana 46202.
 *5) Products derived from this software may not be called NaradaBrokering, 
 * nor may Indiana University or Community Grids Lab or NaradaBrokering appear
 * in their name, without prior written permission of ARTI.
 * 
 *
 * Indiana University provides no reassurances that the source code provided 
 * does not infringe the patent or any other intellectual property rights of 
 * any other entity.  Indiana University disclaims any liability to any 
 * recipient for claims brought by any other entity based on infringement of 
 * intellectual property rights or otherwise.  
 *
 *LICENSEE UNDERSTANDS THAT SOFTWARE IS PROVIDED "AS IS" FOR WHICH NO 
 *WARRANTIES AS TO CAPABILITIES OR ACCURACY ARE MADE. INDIANA UNIVERSITY GIVES
 *NO WARRANTIES AND MAKES NO REPRESENTATION THAT SOFTWARE IS FREE OF 
 *INFRINGEMENT OF THIRD PARTY PATENT, COPYRIGHT, OR OTHER PROPRIETARY RIGHTS. 
 *INDIANA UNIVERSITY MAKES NO WARRANTIES THAT SOFTWARE IS FREE FROM "BUGS", 
 *"VIRUSES", "TROJAN HORSES", "TRAP DOORS", "WORMS", OR OTHER HARMFUL CODE.  
 *LICENSEE ASSUMES THE ENTIRE RISK AS TO THE PERFORMANCE OF SOFTWARE AND/OR 
 *ASSOCIATED MATERIALS, AND TO THE PERFORMANCE AND VALIDITY OF INFORMATION 
 *GENERATED USING SOFTWARE.
 */
package cgl.narada.jms;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;

import javax.jms.JMSException;
import javax.jms.TextMessage;

/** 
   This class implements the TextMessage based on its definition contained
   with the JMS specification.

   @author Shrideep Pallickara
   $Revision$
   $Date$
*/


public class JmsTextMessage extends JmsMessage 
  implements TextMessage, JmsDebugFlags  {
  
  /** The text message contained in this Message */
  private String textMessage="";
  
  
  public JmsTextMessage(byte[] textMessageBytes) {
    ByteArrayInputStream baInputStream = 
      new ByteArrayInputStream(textMessageBytes);
    DataInputStream din = new DataInputStream(baInputStream);
    
    try {
      int headerAndPropertyLength = din.readInt();
      byte[] headerPropBytes = new byte[headerAndPropertyLength];
      din.readFully(headerPropBytes);
      super.unmarshallJmsMessage(headerPropBytes);
      
      textMessage = din.readUTF();
    } catch (IOException ioe) {
      System.out.println("JmsTextMessage:: Error in unmarshalling");
    }
    
    try {
      setJMSType("TextMessage");
    } catch (JMSException jmsEx) {
      System.out.println(jmsEx);
    }

  }
  
  public JmsTextMessage() {
    super();
    try {
      setJMSType("TextMessage");
    } catch (JMSException jmsEx) {
      System.out.println(jmsEx);
    }
  }
  
  
  public void setText(String string) throws JMSException {
    testWriteBody();
    if (JmsTextMessage_Debug) {
      System.out.println("JmsTextMessage: Setting text in TextMessage to ("+ 
			 string +")");
    }
    
    if (string == null) {
      throw new JMSException("The message is a NULL Message ");
    }
    textMessage = string;
  }
  
  
  public String getText() throws JMSException {
    if (textMessage == null) {
      throw new JMSException("The message is a NULL Message ");
    }
    return textMessage; 
  }
  
  public void clearBody() throws JMSException {
    textMessage = "";
  }

  public byte[] getBytes() {
    ByteArrayOutputStream baOutputStream = new ByteArrayOutputStream();
    DataOutputStream dout = new DataOutputStream(baOutputStream);
    byte[] marshalledBytes = null;
    try {
      byte[] headerPropBytes = super.getBytes();
      /* Write the length of the byte Stream comprising headers and properties
	 first.*/
      dout.writeInt(headerPropBytes.length);
      dout.write(headerPropBytes);
      dout.writeUTF(textMessage);
      
      dout.flush();
      marshalledBytes = baOutputStream.toByteArray();
    } catch (IOException ioe) {
      System.out.println("JmsTextMessage: Error marshalling TextMessage");
    }/* end try-catch block */
    return marshalledBytes;
  }

  public String toString() {
    String stringRep = super.toString() + "\n" + 
      "TextMessage Body >> " + textMessage;
    return stringRep;
  }


  public static void main(String[] args) {
    JmsTextMessage txtMessage = new JmsTextMessage();
    try {
      txtMessage.setText("Jordan rules ...");
      txtMessage.setStringProperty("Test", "Property Value being tested");
      txtMessage.setJMSMessageID("Shrideep's Test Header");
      txtMessage.setJMSTimestamp(System.currentTimeMillis());
      txtMessage.setJMSCorrelationID("Wizards-Bulls-Jordan");
      //txtMessage.setJMSType("CoolType");
      txtMessage.setJMSExpiration((long)20);
      txtMessage.setJMSPriority(2);
    } catch (JMSException jmsEx) {
      System.out.println("Some error initializing header " + jmsEx);
    }
    byte[] txtMessageBytes = txtMessage.getBytes();
    JmsTextMessage txtMsg = new JmsTextMessage(txtMessageBytes);
    System.out.println(txtMsg);
        
  }
}









